asyncio - 不止一次等待协程（周期性任务）

Question

我正在尝试为 asyncio 事件循环创建一个周期性任务，如下所示，但是我收到 "RuntimeError: cannot reuse already awaited coroutine" 异常。显然，asyncio 不允许等待 this bug thread 中讨论的相同可等待函数。这就是我尝试实现它的方式：

import asyncio    

class AsyncEventLoop:    

    def __init__(self):
        self._loop = asyncio.get_event_loop()

    def add_periodic_task(self, async_func, interval):
        async def wrapper(_async_func, _interval):
            while True:
                await _async_func               # This is where it goes wrong
                await asyncio.sleep(_interval)
        self._loop.create_task(wrapper(async_func, interval))
        return

    def start(self):
        self._loop.run_forever()
        return

由于我的 while 循环，相同的可等待函数 (_async_func) 将在其间的睡眠间隔内执行。我从 How can I periodically execute a function with asyncio? 中获得了实现周期性任务的灵感？ .

从上面提到的错误线程中，我推断出 RuntimeError 背后的想法是为了让开发人员不会意外地等待同一个协程两次或更多次，因为协程将被标记为完成并产生 None 而不是结果。有没有办法让我多次等待同一个函数？

Answer 1

您似乎混淆了异步函数（协程函数）和协程 - 这些异步函数产生的值。

考虑这个异步函数：

async def sample():
    await asyncio.sleep(3.14)

您正在传递其调用结果：add_periodic_task(sample(), 5)。

相反，您应该传递异步函数对象本身：add_periodic_task(sample, 5)，并在您的包装器中调用它：

while True:
    await _async_func()
    await asyncio.sleep(_interval)

asyncio - 不止一次等待协程（周期性任务）

asyncio - await coroutine more than once (periodic tasks)

python

scheduled-tasks

periodic-task

python-asyncio